package com.ddxz.flink.join

import org.apache.flink.streaming.api.functions.co.ProcessJoinFunction
import org.apache.flink.util.Collector

object DdxzJoin extends ProcessJoinFunction[(String, String, Int, Long, String, String), (String, String, String, String), String] {
  override def processElement(in1: (String, String, Int, Long, String, String),
                              in2: (String, String, String, String),
                              context: ProcessJoinFunction[(String, String, Int, Long, String, String),
                                (String, String, String, String), String]#Context, collector: Collector[String]): Unit = {
    System.out.println("rel: " + in1 + "\ncol: " + in2)
  }
}
